package com.hm.kafkatest2.entity;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableField;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;

import java.time.LocalDateTime;

@Data
@TableName("kafka_message")
public class KafkaMessage {
    
    /**
     * 主键ID
     */
    @TableId(type = IdType.AUTO)
    private Long id;
    
    /**
     * Kafka集群地址
     */
    private String bootstrapServers;
    
    /**
     * Topic名称
     */
    private String topic;
    
    /**
     * 消费组ID
     */
    private String groupId;
    
    /**
     * 分区
     */
    @TableField("\"partition\"")
    private Integer partition;
    
    /**
     * 消息偏移量
     */
    @TableField("\"offset\"")
    private Long offset;
    
    /**
     * 消息内容
     */
    private String message;
    
    /**
     * 唯一标识
     */
    private String uniqueId;
    
    /**
     * 创建时间
     */
    private LocalDateTime createTime;
}